import csv
from io import StringIO

import pandas as pd
from 小区健康度.Batch import batch
if __name__ == '__main__':
    from pg.获取pg连接 import insert_csv_to_pg

    insert_csv_to_pg(f"D:\\家宽\\小区底表\\小区底表{batch}.csv", ['小区ID', '小区', '分公司'], "小区底表")
    insert_csv_to_pg(f"D:\\家宽\\小区底表\\小区底表传输{batch}.csv", ['小区ID', '小区', '分公司'], "小区底表传输")

    insert_csv_to_pg("D:\\家宽\\综资\\综资数据(更新至2025年7月29日)\\OLT业务表的配置查询结果.csv",
                     ['管理IP', '网元名称', '所属机房'], "OLT业务表的配置查询结果", encoding='gbk')
    insert_csv_to_pg('/网管/用户数和板卡数.csv', None, '网管用户数和板卡数')
